//package com.aisile.rabbitmq.config;
//
//import org.springframework.amqp.core.*;
//import org.springframework.beans.factory.annotation.Qualifier;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
///**
// * @Auther:yry
// * @Date:2024/1/2 0002
// * @VERSON:1.0
// */
//@Configuration
//public class RabbitMQConfigv2 {
//
//    // TEST_EXCHANGE 交换机名称
//    public static final String TEST_EXCHANGE = "test_exchange1";
//    // TEST_QUEUE 队列名称
//    public static final String TEST_QUEUE1 = "test_queue1";
//    public static final String TEST_QUEUE2 = "test_queue2";
//
//    // 声明队列
//    @Bean(TEST_QUEUE1)
//    public Queue TEST_QUEUE1(){
//        return new Queue(TEST_QUEUE1,true);
//    }
//    @Bean(TEST_QUEUE2)
//    public Queue TEST_QUEUE2(){
//        return new Queue(TEST_QUEUE2,true);
//    }
//
//    // 声明交换机
//    @Bean(TEST_EXCHANGE)
//    public Exchange TEST_EXCHANGE(){
//        return ExchangeBuilder.directExchange(TEST_EXCHANGE).durable(true).build();
//    }
//
//    // 绑定队列和交换机
//
//    @Bean
//    public Binding TEST_EXCHANGE_QUEUE1(@Qualifier(TEST_EXCHANGE) Exchange exchange,@Qualifier(TEST_QUEUE1) Queue queue){
//        return BindingBuilder.bind(queue).to((DirectExchange) exchange).with("test1");
//    }
//    @Bean
//    public Binding TEST_EXCHANGE_QUEUE2(@Qualifier(TEST_EXCHANGE) Exchange exchange,@Qualifier(TEST_QUEUE2) Queue queue){
//        return BindingBuilder.bind(queue).to((DirectExchange) exchange).with("test2");
//    }
//
//}
